package internal

//func allMemberPushHandler(msg *stan.Msg) {
//	var s imsdk.OfflineMsgNats
//	err := json.Unmarshal(msg.Data, &s)
//	if err != nil {
//		global.Log.Errorf("allMemberPushHandler Unmarshal error: %v", err)
//		return
//	}
//	var o imsdk.OfflineMsg
//
//	err = o.SendOfflineMsg(s.OfflineArgs, s.Condition, s.User, s.Title, s.Content)
//	if err != nil {
//		global.Log.Errorf("allMemberPushHandler SendOfflineMsg error: %v", err)
//		return
//	} else {
//		global.Log.Infof("allMemberPushHandler: %s", string(msg.Data))
//	}
//
//	time.Sleep(1 * time.Second)
//}

//func ImTagHandler(msg *stan.Msg) {
//	var tagHandle imsdk.TagHandle
//	err := json.Unmarshal(msg.Data, &tagHandle)
//	if err != nil {
//		global.Log.Errorf("解析消息失败,err:%v", err)
//		return
//	}
//
//	if tagHandle.IsAdd {
//		imsdk.GetSdk().AddTags(tagHandle.ToAccount, tagHandle.Tags)
//		global.Log.Infof("添加标签成功,用户數量:%v,标签:%s", len(tagHandle.ToAccount), tagHandle.Tags)
//	} else {
//		imsdk.GetSdk().DeleteTags(tagHandle.ToAccount, tagHandle.Tags)
//		global.Log.Infof("删除标签成功,用户數量:%v,标签:%s", len(tagHandle.ToAccount), tagHandle.Tags)
//	}
//
//	timehelper.Sleep(1 * timehelper.Second)
//
//}
